ConcurrentReplayLatestSubjectAsync class¶

Defined in

Namespace: ReactiveUI.Extensions.Async.Subjects Assembly: ReactiveUI.Extensions.dll Full name: ReactiveUI.Extensions.Async.Subjects.ConcurrentReplayLatestSubjectAsync<T> Modifiers: public sealed

Summary¶

View source

        Represents an asynchronous subject that replays only the latest value to new observers and supports concurrent
        notification of observers.

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

Class hierarchy

classDiagram
class ConcurrentReplayLatestSubjectAsync~T~
class BaseReplayLatestSubjectAsync~T~
BaseReplayLatestSubjectAsync~T~ <|-- ConcurrentReplayLatestSubjectAsync~T~

Inherits from: BaseReplayLatestSubjectAsync

Remarks¶

This subject notifies all observers concurrently, which can improve throughput in scenarios with multiple observers. The order in which observers receive notifications is not guaranteed. This type is thread-safe and suitable for use in asynchronous and concurrent environments.

Constructors¶

Name	Summary
.ctor	Represents an asynchronous subject that replays only the latest value to new observers and supports concurrent notification of observers.

Methods¶

Name	Summary
OnNextAsyncCore	Asynchronously notifies all observers in the collection with the specified value.
OnErrorResumeAsyncCore	Asynchronously notifies all observers of an error and resumes processing, if possible.
OnCompletedAsyncCore	Notifies all observers that the asynchronous operation has completed, forwarding the specified result to each observer.

Inherited members